
package com.demo.rabbitmq.config;

import org.springframework.amqp.core.Queue;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author yexi
 */
@Configuration
public class RabbitMqConfig {

    /**
     * 基于Jackson2的JSON转换器，生产消息时会将消息通过此转化器转换后再发送。
     */
    @Bean
    public Jackson2JsonMessageConverter messageConverter() {
        return new Jackson2JsonMessageConverter();
    }

    /**
     * 声明队列，如果队列不存在则会自动创建。目前这里声明只是为了自动创建队列，暂无其他用处。
     */
    @Bean
    protected Queue queue() {
        Queue queue = new Queue("testQueue");
        return queue;
    }

}
